/**
 * 访问test数据库
 */

const mysql= require('mysql');
const pool=mysql.createPool({
    connectionLimit : 10,
    host            :'127.0.0.1',
    user            :'root',
    password        :'XR20020623',
    database        :'test'
});

/**
 * 获取sql执行结果
 * @returns  {Promise}
 */
function query(sql, values){
    return new Promise((resolve,reject)=>{
        //连接池获取连接
        pool.getConnection((error,connection)=>{
            if(error){
                reject(error);
            }else{
                // 执行sql语句
                connection.query(sql,values,(error,results)=>{
                    //释放连接
                    connection.release();
                    if(error){
                        reject(error);
                    }else{
                        resolve(results);
                    }
                });
            }
        });
    });
}

module.exports = {query};